package example;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;

public class Main {
    public static void main(String[] args) throws IOException {

        /**
         * 设计原则：本工具应该像坟墓一般简洁
         * 文件路径
         * 集群地址
         * topic名称
         * 线程数
         * 动态读取的kafka的配置文件地址，配置更改的生效方式
         *
         * 影响因素：文件大小、读取方式、线程数、kafka接收的确认机制、kafka集群的大小
         * 评价指标：不能丢数据，时间尽可能短
         *
         * 控制变量：文件大小：700m，读取方式BufferedReader，线程数3，kafka接收的确认机制1，集群大小3
         */

        File file = new File("MIS_CUSTLABEL_B00750_20241129.txt");

        if(file.exists()){
            file.delete();
        }

        file.createNewFile();

        BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter(file));

        for (int i = 0; i < 30000000; i++) {
//            if(i != 30000000){
                bufferedWriter.write("001900448844" + i + "|" + (i % 3) + "|" + (i % 100) + "\n");
//            }else {
//                bufferedWriter.write("001900448844" + i + "|" + (i % 3) + "|" + (i % 100));
//            }
        }

        bufferedWriter.flush();
        bufferedWriter.close();




    }
}